package com.rocketmq.consumer.manage;

/**
 * Topic监听启动接口
 *
 * @author xuziwen
 * @create 2017-08-15 17:48
 */
public interface RocketMqManager {

    void start() throws Exception;

    void stop();
}
